package cc.laop.mq.kafka.consumer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;
import java.util.Currency;

/**
 * Created by Pengpeng on 2017/5/26.
 */
public class Consumer {

    private static final Logger logger = LoggerFactory.getLogger(Consumer.class);

    public static void main(String[] args) throws IOException {
        new Thread(() -> {
            logger.info("Consumer starting...");
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext
                    ("classpath:spring/spring-kafka-consumer.xml");
            context.start();
            logger.info("Consumer started.");
        }).start();
        System.in.read();
    }

}
